//package com.dataextend.manage;
//
//import com.alibaba.fastjson.JSONObject;
//import com.dataextend.config.RedisClientModel;
//import org.apache.kafka.clients.consumer.ConsumerRecord;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.kafka.annotation.KafkaListeners;
//import org.springframework.stereotype.Component;
//
//@Component
//public class KafkaConsumer {
//    @Autowired
//    protected RedisClientModel redis;
//
//    @KafkaListener(topics = "userprofile", containerFactory="ManualKafkaContainerFactory")
//    public void listen(ConsumerRecord<Integer, String> msg) {
//        // 消费到数据后的处理逻辑
//        JSONObject obj = JSONObject.parseObject(msg.value());
//
//        System.out.println(">>>>>>>>>>:" +obj);
//        System.out.println(">>>>>>>>>>:" +redis.get("30010762814443275"));
//    }
//
//}
